package com.jiuzhi.kafka.util;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class ConsumerUtil {

	
	/**
	 * 
	 * @param data
	 */
	@KafkaListener(topics="test-jiuzhi-log1")
	public void receiveData(String data) {
		
		 
	}
	
	@KafkaListener(topics= {"test-jiuzhi-log2"})
	public void receiveDataListen(ConsumerRecord<?, ?> record) {
		
		record.key();
		record.value();
	}
}
